import os
import sys
from celery import Celery

B_DIR = os.path.dirname(os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
sys.path.insert(1, B_DIR)
sys.path.insert(0, os.path.join(B_DIR, 'utils'))

# 创建celery实例
celery_app = Celery('mangguo')

# 加载配置文件
celery_app.config_from_object('celery_tasks.config')

# 加载异步任务
celery_app.autodiscover_tasks(['celery_tasks.sms'])
